Automate user curation

kitsune/settings.py

@@ -1127,6 +1127,7 @@ def filter_exceptions(event, hint):
 DMS_FIX_CURRENT_REVISIONS = config("DMS_FIX_CURRENT_REVISIONS", default=None)
 DMS_COHORT_ANALYSIS = config("DMS_COHORT_ANALYSIS", default=None)
 DMS_UPDATE_L10N_CONTRIBUTOR_METRICS = config("DMS_UPDATE_L10N_CONTRIBUTOR_METRICS", default=None)
+DMS_CLEANUP_EXPIRED_USERS = config("DMS_CLEANUP_EXPIRED_USERS", default=None)
 
 PROD_DETAILS_CACHE_NAME = "product-details"
 PROD_DETAILS_STORAGE = config(
@@ -1331,3 +1332,5 @@ def filter_exceptions(event, hint):
 
 SUMO_BOT_USERNAME = config("SUMO_BOT_USERNAME", default="SumoBot")
 SUMO_CONTENT_GROUP = config("SUMO_CONTENT_GROUP", default="Staff Content Team")
+
+USER_INACTIVITY_DAYS = config("USER_INACTIVITY_DAYS", default=1095, cast=int)

kitsune/users/management/commands/cleanup_expired_users.py

@@ -0,0 +1,27 @@
+from datetime import timedelta
+
+from django.conf import settings
+from django.contrib.auth import get_user_model
+from django.core.management.base import BaseCommand
+from django.utils import timezone
+
+from kitsune.users.utils import delete_user_pipeline
+
+
+class Command(BaseCommand):
+    help = "Delete users who haven't logged in for more than settings.USER_INACTIVITY_DAYS days"
+
+    def handle(self, *args, **options):
+        User = get_user_model()
+        expiration_date = timezone.now() - timedelta(days=settings.USER_INACTIVITY_DAYS)
+
+        expired_users = User.objects.filter(last_login__lt=expiration_date)
+        self.stdout.write(f"Found {expired_users.count()} expired users")
+
+        for user in expired_users:
+            delete_user_pipeline(user)
+            self.stdout.write(f"Deleted user {user.username}")
+
+        self.stdout.write(
+            self.style.SUCCESS(f"Successfully processed {expired_users.count()} expired users")
+        )

scripts/cron.py

@@ -4,6 +4,7 @@
 from subprocess import check_call
 
 import babis
+import waffle
 from apscheduler.schedulers.blocking import BlockingScheduler
 from django.conf import settings
 from django.utils import timezone
@@ -399,6 +400,22 @@ def job_cleanup_old_account_events():
     call_command("cleanup_old_account_events")
 
 
+@scheduled_job(
+    "cron",
+    month="*",
+    day="*",
+    hour="03",
+    minute="00",
+    day_of_week=0,
+    max_instances=1,
+    coalesce=True,
+    skip=(settings.READ_ONLY or not waffle.switch_is_active('cleanup-expired-users')),
+)
+@babis.decorator(ping_after=settings.DMS_CLEANUP_EXPIRED_USERS)
+def job_cleanup_expired_users():
+    call_command("cleanup_expired_users")
+
+
 def run():
     try:
         schedule.start()